
var mysql = require('mysql');
const { dbConfig } = require('../../../config');
var pool = mysql.createPool(dbConfig);

var db = {};

db.query = function (sql, params) {

  return new Promise((resolve, reject) => {
    // 取出链接
    pool.getConnection(function (err, connection) {

      if (err) {
        reject(err);
        return;
      }

      connection.query(sql, params, function (error, results, fields) {
        console.log(`${ sql }=>${ params }`);
        // 释放连接
        connection.release();
        if (error) {
          reject(error);
          return;
        }
        resolve(results);
      });

    });
  });
}
// 导出对象
module.exports = db;
// 数据库连接助手
/**const mysql = require('mysql');

class db{
  // 获取数据库连接
  getConn(){
    let conn = mysql.createConnection({
      // 数据库连接配置
      host:'localhost',
      port:'3306',
      user:'root',				// Mysql管理员用户名
      password:'huiyu20000128',			// Mysql管理员密码
      database:'resource'  			// 数据库名
    });
    conn.connect();
    return conn;
  }
}

module.exports = db;**/


